[consumer]
kafka_server_list={{ kafka_server_list }}
group_id=DiagGroup
enable_auto_commit=False
auto_offset_reset=earliest
timeout_ms=5
max_records=3

[topic]
name=DIAGNOSE_EXECUTE_REQ

